package com.gancp.jms.impl;

import com.gancp.jms.IProducer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Service;

import javax.jms.Destination;

/**
 * @Author gancp
 * @Date 时间被黑洞吸走了
 * @Descripition JMS-AMQ消息队列 生产者
 **/
@Service
@Slf4j
public class Producer implements IProducer {

    /**
     * @Author gancp
     * @Date 时间被黑洞吸走了
     * @Descripition 消息模板操作类（类似spring jdbctemplete）
     **/
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;

    /**
     * @Author gancp
     * @Date 时间被黑洞吸走了
     * @Descripition 发送消息，destination是发送到的队列，message是待发送的消息
     **/
    @Override
    public void sendMessage(Destination destination, String message) {
        log.info( "amq正在准备发送短信：" + message );
        jmsMessagingTemplate.convertAndSend( destination, message );
    }


}
